package com.etl.process.schedule.task;

/**
 * 检测任务线程
 */
public class DetectTask {

    /**
     * 检测任务
     *  也是一个线程 就是一个观察者模式
     *  检测任务执行了没有
     *  通过execute_ins获取所有的IP + 端口号 再循环获取到分配的每段任务
     *  然后通过任务段id 获取每段每一个任务段线程的刷新时间
     *  如果线程刷新时间间隔过长 会再次启动另一个心跳线程 对这个服务进行启动
     *  但是心跳携带的是任务段Id
     *  启动后
     *  会返回给他一个心跳值   当前时间 - 最近刷新时间
     *  再次去刷新以任务段为id的线程刷新时间
     *  如果这个任务段长时间未刷新   可以判定这个任务一场结束
     *      方案  先进性本次记录进行保存
     *           若再次发生异常停止  则进行邮件提示
     *
     */


}
